package cn.yi.fast.mq.rocketmq.message.handler;

import cn.yi.fast.mq.rocketmq.coder.MessageDecoder;
import com.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import com.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import com.alibaba.rocketmq.common.message.MessageExt;

public interface MessageHandler<T> {
    ConsumeConcurrentlyStatus process(T data, MessageExt msg, ConsumeConcurrentlyContext context);

    MessageDecoder<T> getMessageDecoder();
}
